package com.jin.spring_boot_learn.jin;

import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

public class Application {
    public static void main(String[] args) throws InterruptedException {
        Flux.range(1, 6)
                .map(i -> 10 / (3 - i))
                .retry(1)
                .subscribe(System.out::println, System.err::println);

        Thread.sleep(100);  // 确保序列执行完
        Mono<String> hello_world = Mono.just("Hello World");



    }


}
